const redis = require('redis');
const dotenv = require('dotenv');

// 加载环境变量
dotenv.config();

// 创建Redis客户端
const redisClient = redis.createClient({
    socket: {
        host: process.env.REDIS_HOST,
        port: process.env.REDIS_PORT
    },
    password: process.env.REDIS_PASSWORD,
    database: parseInt(process.env.REDIS_DB)
});

// 处理Redis连接错误
redisClient.on('error', (err) => {
    console.error('Redis连接错误:', err);
});

// 连接Redis
async function connectRedis() {
    try {
        await redisClient.connect();
        console.log('Redis连接成功');
    } catch (error) {
        console.error('Redis连接失败:', error);
    }
}

connectRedis();

module.exports = redisClient;